package org.mics.mq.rocketmq.aliyun.transaction;

import com.aliyun.openservices.ons.api.Message;
import com.aliyun.openservices.ons.api.transaction.LocalTransactionChecker;
import com.aliyun.openservices.ons.api.transaction.TransactionStatus;
import org.springframework.stereotype.Component;

@Component
public class DemoLocalTransactionChecker implements LocalTransactionChecker {
   
	@Override
    public TransactionStatus check(Message msg) {
		//根据本地事务状态检查结果返回不同的TransactionStatus
        return TransactionStatus.CommitTransaction; 
    }
	
}
